import lancedb
import pandas as pd
import pyarrow as pa

uri = "data/sample-lancedb"
db = lancedb.connect(uri)
# 异步客户端
#async_db = await lancedb.connect_async(uri)

data = [
    {"vector": [3.1, 4.1], "item": "foo", "price": 10.0},
    {"vector": [5.9, 26.5], "item": "bar", "price": 20.0},
]

# 如果表名已经存在，则会报错。如果希望覆盖已经创建的同名表，可以添加mode='overwrite'参数。
#tbl = db.create_table("my_table", data=data)
#tbl = db.create_table("my_table", data=data, mode='overwrite')
#如果不希望覆盖已经创建的同名表，而直接打开的话，可以添加exist_ok=True参数。
tbl = db.create_table("my_table", data=data, exist_ok=True)